package com.cm.cloudeureka.basic.ui.controller;



//rabbitmq
//@Named
//@Slf4j
//@EnableBinding(InfoCouponSink.class)
public class InfoCouponLisenller {

//    @Autowired
//    private NotificationClient notificationClient;
//
//    @org.springframework.cloud.stream.annotation.StreamListener(InfoCouponSink.INPUT)
//    public void process(CouponInfo payMessage) {
//        int i = payMessage.getStatus();
//        log.info("收到消息");
//        Notification info = new Notification();
//        info.setType(EnumNotificationType.GET_COUPON.name());
//        info.setState(StatusEnums.SUCCESS.getKey());
//        info.setUserId(payMessage.getUserId());
//        info.setNotifyTime(LocalDateTime.now());
//        info.setContent(payMessage.getContext());
//        info.setTargetValue(payMessage.getId());
//        notificationClient.save(info);
//    }
}
